Node / ReticulumProjects / MeshChatX.git / files / vendor / rns_filesync / tests / exploratory / test_exploratory.py

Displaying Raw • Download

T8b949e"""Exploratory stress tests using the two-peer TCP harness."""

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72import T7ee787pytest

Tff7b72from T7ee787testsT7ee787.T7ee787e2eT7ee787.T7ee787rns_helpers Tff7b72import Te6edf3TwoPeerHarnessTb4b4b4, Te6edf3wait_until

Te6edf3pytestmark Tff7b72= Tb4b4b4[Te6edf3pytestTff7b72.Td2a8ffmarkTff7b72.Td2a8ffexploratoryTb4b4b4]

Tff7b72def Td2a8fftest_many_small_filesTb4b4b4(Te6edf3tmp_pathTb4b4b4)Tb4b4b4:

Te6edf3h Tff7b72= Te6edf3TwoPeerHarnessTb4b4b4(Te6edf3tmp_pathTb4b4b4)

Tff7b72for Te6edf3i Tff7b72in Tffa657rangeTb4b4b4(T79c0ff25Tb4b4b4)Tb4b4b4:

Tb4b4b4(Te6edf3hTff7b72.Td2a8ffdir_b Tff7b72/ Ta5d6fffTa5d6ff"Ta5d6fffTffd700{Te6edf3iTffd700}Ta5d6ff.txtTa5d6ff"Tb4b4b4)Tff7b72.Td2a8ffwrite_textTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffpayload-Tffd700{Te6edf3iTffd700}Ta5d6ff"Tb4b4b4)

Te6edf3hTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72assert Te6edf3wait_untilTb4b4b4(

Tff7b72lambdaTb4b4b4: Tffa657allTb4b4b4(Tb4b4b4(Te6edf3hTff7b72.Td2a8ffdir_a Tff7b72/ Ta5d6fffTa5d6ff"Ta5d6fffTffd700{Te6edf3iTffd700}Ta5d6ff.txtTa5d6ff"Tb4b4b4)Tff7b72.Td2a8ffis_fileTb4b4b4(Tb4b4b4) Tff7b72for Te6edf3i Tff7b72in Tffa657rangeTb4b4b4(T79c0ff25Tb4b4b4)Tb4b4b4)Tb4b4b4,

Te6edf3timeoutTff7b72=T79c0ff120.0Tb4b4b4,

Tb4b4b4)

Tff7b72finallyTb4b4b4:

Te6edf3hTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8fftest_nested_and_emptyTb4b4b4(Te6edf3tmp_pathTb4b4b4)Tb4b4b4:

Te6edf3h Tff7b72= Te6edf3TwoPeerHarnessTb4b4b4(Te6edf3tmp_pathTb4b4b4)

Te6edf3nested Tff7b72= Te6edf3hTff7b72.Td2a8ffdir_b Tff7b72/ Ta5d6ff"Ta5d6ffsubTa5d6ff" Tff7b72/ Ta5d6ff"Ta5d6ffdirTa5d6ff"

Te6edf3nestedTff7b72.Td2a8ffmkdirTb4b4b4(Te6edf3parentsTff7b72=Tff7b72TrueTb4b4b4)

Tb4b4b4(Te6edf3nested Tff7b72/ Ta5d6ff"Ta5d6ffemptyTa5d6ff"Tb4b4b4)Tff7b72.Td2a8ffwrite_bytesTb4b4b4(Ta5d6ffbTa5d6ff"Ta5d6ff"Tb4b4b4)

Tb4b4b4(Te6edf3nested Tff7b72/ Ta5d6ff"Ta5d6ffdataTa5d6ff"Tb4b4b4)Tff7b72.Td2a8ffwrite_bytesTb4b4b4(Ta5d6ffbTa5d6ff"Ta5d6ffnested-dataTa5d6ff"Tb4b4b4)

Te6edf3hTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72assert Te6edf3wait_untilTb4b4b4(

Tff7b72lambdaTb4b4b4: Tb4b4b4(Te6edf3hTff7b72.Td2a8ffdir_a Tff7b72/ Ta5d6ff"Ta5d6ffsubTa5d6ff" Tff7b72/ Ta5d6ff"Ta5d6ffdirTa5d6ff" Tff7b72/ Ta5d6ff"Ta5d6ffdataTa5d6ff"Tb4b4b4)Tff7b72.Td2a8ffis_fileTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3timeoutTff7b72=T79c0ff90.0Tb4b4b4,

Tb4b4b4)

Tff7b72assert Tb4b4b4(Te6edf3hTff7b72.Td2a8ffdir_a Tff7b72/ Ta5d6ff"Ta5d6ffsubTa5d6ff" Tff7b72/ Ta5d6ff"Ta5d6ffdirTa5d6ff" Tff7b72/ Ta5d6ff"Ta5d6ffemptyTa5d6ff"Tb4b4b4)Tff7b72.Td2a8ffis_fileTb4b4b4(Tb4b4b4)

Tff7b72assert Tb4b4b4(Te6edf3hTff7b72.Td2a8ffdir_a Tff7b72/ Ta5d6ff"Ta5d6ffsubTa5d6ff" Tff7b72/ Ta5d6ff"Ta5d6ffdirTa5d6ff" Tff7b72/ Ta5d6ff"Ta5d6ffemptyTa5d6ff"Tb4b4b4)Tff7b72.Td2a8ffstatTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ffst_size Tff7b72== T79c0ff0

Tff7b72finallyTb4b4b4:

Te6edf3hTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)